/*
 * @Description: 
 * @Author: changqing
 * @Date: 2021-08-30 12:38:10
 * @LastEditTime: 2021-08-30 12:40:13
 * @LastEditors: changqing
 * @Usage: 
 */
var { timer, interval } = require('rxjs'); 
var {take,single} = require('rxjs/operators');
timer(0, 1000).pipe(
  take(6)
).subscribe({
  next: data => console.log(`take 示例: ${data}`),
  complete: () => console.log(`take complete`),
});
// 0 1 2 3 4 5